﻿using System;
using System.Collections.Generic;
using System.Text;

namespace Common.MQ
{
    /// <summary>
    /// 消息处理程序接口
    /// </summary>
    public interface IMessageHandler
    {
        /// <summary>
        /// 消息数据类型
        /// </summary>
        Type DataType { get; }
        /// <summary>
        /// 处理消息，如果需要消费掉消息，请返回true，返回false时消息会被重试5次
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        bool Handle(string json);
    }
}
